import celery

rabbitmq_broker = 'amqp://admin:123456@10.4.7.20:5672'
redis_backend = 'redis://10.4.7.10:6379/1'

include_tasks = [
    'task01',
    'task02',
]

cel = celery.Celery('app', broker=rabbitmq_broker, backend=redis_backend, include=include_tasks)
cel.conf.timezone = 'Asia/Shanghai'
cel.conf.enable_utc = False
cel.conf.update(broker_connection_timeout=4.0, broker_connection_max_retries=3, broker_connection_retry_on_startup=True)


